# 设置环境
import os

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo_mall.settings')

# 1.创建celery实例
from celery import Celery

app = Celery('celery_tasks')

# 2.设置broker
# 加载配置文件来设置broker
app.config_from_object('celery_tasks.config')

# 3.需要celery自动检测指定包的任务
# app.autodiscover_tasks参数是列表
# 列表中的元素是tasks的路径
app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email'])

"""
    在虚拟环境下执行指令
    celery -A celery实例的路径 -l INFO
    celery -A celery_tasks.main worker -l INFO
    win下：celery -A celery_tasks.main worker -l info -P eventlet  -c 10
    -c是协程的数量，生产环境可以用1000
"""
